//package com.example.hackerrocketmq.consumer;
//
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.core.RocketMQListener;
//import org.springframework.stereotype.Component;
//
///**
// * Description：
// *
// * @Author: cw
// * CreateTime：2022-10-14
// */
//@Component
//@RocketMQMessageListener(topic = "first_topic", consumerGroup = "group-test")
//public class Consumer implements RocketMQListener<String> {
//
//
//    @Override
//    public void onMessage(String s) {
//        System.out.println("消费者收到消息：==="+s);
//    }
//}
